from utils import read_sql, db_config_live



sql = "select script_name, func_name, args from tasks_detail where project_name = 'crypto_quant' "
df1 = read_sql(sql, db_name="task")

set1= set(zip(df1['script_name'], df1['func_name'], df1['args']))
# print(set1)

sql = """select script_name, func_name, args from (

SELECT script_name, func_name, args, sum(`status`) as sum_status FROM `crypto_quant` where date = '2025-10-23' GROUP BY script_name, func_name, args

) as t where t.sum_status >= 1;"""
df2 = read_sql(sql, db_name="task")

set2= set(zip(df2['script_name'], df2['func_name'], df2['args']))
# for x in (set1 - set2):
#     print(x)

for x in (set2 - set1):
    print(x)